package org.ala.tiktools.rocketmq;

import org.ala.tiktools.rocketmq.producer.queue.DefaultQueueSelecter;
import org.ala.tiktools.rocketmq.producer.queue.IQueueSelecter;
import org.ala.tiktools.rocketmq.producer.transaction.DefaultTransactionListener;
import org.apache.rocketmq.client.producer.TransactionListener;

/**
 * @author ala
 * @date 2024-11-29 15:35
 */
public class Namespace {


    /**
     *  NULL值特殊字符串
     */
    public final static String NULL = "NULL";
    /**
     *  无效数字类型
     */
    public final static int INF = Integer.MIN_VALUE;
    /**
     *  NULL的queueSelector
     */
    public final static Class<? extends IQueueSelecter> NULL_SELECTOR = DefaultQueueSelecter.class;
    /**
     *  NULL的DefaultTransactionListener
     */
    public final static Class<? extends TransactionListener> NULL_TRANSACTION = DefaultTransactionListener.class;

    /**
     *  默认组名
     */
    public final static String DEFAULT_GROUP = "default";
}
